package pubsub;

import redis.clients.jedis.Jedis;

/**
 * @Author: qingshan
 * @Date: 2019/9/27 10:55
 */
public class PublishTest {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.110.36", 6379);

        try {
            // 关键步骤：进行密码认证（请替换为你的Redis实际密码）
            jedis.auth("seata@user123");

            // 执行发布操作
            jedis.publish("qingshan-123", "666");
            jedis.publish("qingshan-abc", "pengyuyan");
            System.out.println("消息发布成功");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            if (jedis != null) {
                jedis.close();
            }
        }
    }
}
